package org.qy.star_common.message;

import org.qy.star_common.exception.MQException;

import java.io.IOException;

/**
 * @author yinger
 * @description 函数式接口，处理回调
 * @date 2024/3/20 16:05
 **/
public interface Consumer {
    void handleDelivery(String consumerTag, MessageProperties basicProperties, byte[] body) throws MQException, IOException;
}